﻿using Msung.Core.Kafka.Integration;

namespace Msung.Core.Kafka
{
    public interface IKafkaConsumerProvider : IDisposable
    {
        void DisposeT();
        KafkaConsumer Consumer { get; }

        Task ListenAsync();
    }
}
